//package com.mycompany.rocketmq.producer;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//
//import com.alibaba.rocketmq.client.exception.MQClientException;
//import com.alibaba.rocketmq.client.producer.DefaultMQProducer;
//
//
//public class Myproducer {
//	private final Logger logger = LoggerFactory.getLogger(Myproducer.class);
//
//	private DefaultMQProducer defaultMQProducer;
//	private String producerGroup;
//	private String namesrvAddr;
//
//	/**init-method
//	 * */
//	public void init() throws MQClientException{
//		/*启动日志*/
//		logger.info("defaultMQProducer init");
//		logger.info("producerGroup:"+producerGroup);
//		logger.info("namesrvAddr:"+namesrvAddr);
//
//		/*初始化*/
//		defaultMQProducer = new DefaultMQProducer(producerGroup);
//		defaultMQProducer.setNamesrvAddr(namesrvAddr);
//		defaultMQProducer.setInstanceName(String.valueOf(System.currentTimeMillis()));
//
//		/*启动*/
//		defaultMQProducer.start();
//		logger.info("defaultMQProducer start success!");
//	}
//
//	/**destroy-method
//	 * */
//	public void destroy(){
//		defaultMQProducer.shutdown();
//	}
//
//	/**获取DefaultMQProducer
//	 * */
//	public DefaultMQProducer getDefaultMQProducer(){
//		return defaultMQProducer;
//	}
//
//	/**setter method
//	 * */
//	public void setProducerGroup(String producerGroup) {
//		this.producerGroup = producerGroup;
//	}
//
//	public void setNamesrvAddr(String namesrvAddr) {
//		this.namesrvAddr = namesrvAddr;
//	}
//
//}
